/*
 * This program is free software: you can redistribute it and/or modify it under
 * the terms of the GNU General Public License as published by the Free Software
 * Foundation, either version 3 of the License, or (at your option) any later
 * version.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
 * details.
 *
 * You should have received a copy of the GNU General Public License along with
 * this program. If not, see <http://www.gnu.org/licenses/>.
 */
package net.sf.l2j.gameserver.model.entity;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Calendar;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;

import javolution.util.FastList;
import javolution.util.FastMap;
import net.sf.l2j.Config;
import net.sf.l2j.database.L2DatabaseFactory;
import net.sf.l2j.gameserver.Announcements;
import net.sf.l2j.gameserver.ThreadPoolManager;
import net.sf.l2j.gameserver.datatables.ClanTable;
import net.sf.l2j.gameserver.datatables.DoorTable;
import net.sf.l2j.gameserver.instancemanager.FortManager;
import net.sf.l2j.gameserver.model.L2Clan;
import net.sf.l2j.gameserver.model.L2Object;
import net.sf.l2j.gameserver.model.actor.instance.L2DoorInstance;
import net.sf.l2j.gameserver.model.actor.instance.L2PcInstance;
import net.sf.l2j.gameserver.model.zone.type.L2FortZone;
import net.sf.l2j.gameserver.network.serverpackets.PledgeShowInfoUpdate;

/**
 * @author Vice [L2JOneo]
 */
public class Fort {
	protected static Logger _log = Logger.getLogger(Fort.class.getName());
	// =========================================================
	// Data Field
	private int _fortId = 0;
	private List<L2DoorInstance> _doors = new FastList<L2DoorInstance>();
	private List<String> _doorDefault = new FastList<String>();
	private String _name = "";
	private int _ownerId = 0;
	@SuppressWarnings("unused")
	private int _lease;
	private FortSiege _siege = null;
	private Calendar _siegeDate;
	private int _siegeDayOfWeek = 7; // Default to saturday
	private int _siegeHourOfDay = 20; // Default to 8 pm server time
	private int _taxPercent = 0;
	private double _taxRate = 0;
	private int _treasury = 0;
	private L2FortZone _zone;
	protected final int _chRate = 604800000;
	protected boolean _isFree = true;
	private L2Clan _formerOwner = null;
	private Map<Integer, FortFunction> _function;
	private int _nbArtifact = 1;
	private Map<Integer, Integer> _engrave = new FastMap<Integer, Integer>();
	/** Fortress Functions */
	public static final int FUNC_TELEPORT = 1;
	public static final int FUNC_RESTORE_HP = 2;
	public static final int FUNC_RESTORE_MP = 3;
	public static final int FUNC_RESTORE_EXP = 4;
	public static final int FUNC_SUPPORT = 5;

	public class FortFunction {
		private int _type;
		private int _lvl;
		protected int _fee;
		protected int _tempFee;
		private long _rate;
		private long _endDate;
		protected boolean _inDebt;
		public boolean _cwh;

		public FortFunction(int type, int lvl, int lease, int tempLease,
				long rate, long time, boolean cwh) {
			_type = type;
			_lvl = lvl;
			_fee = lease;
			_tempFee = tempLease;
			_rate = rate;
			_endDate = time;
			initializeTask(cwh);
		}

		public int getType() {
			return _type;
		}

		public int getLvl() {
			return _lvl;
		}

		public int getLease() {
			return _fee;
		}

		public long getRate() {
			return _rate;
		}

		public long getEndTime() {
			return _endDate;
		}

		public void setLvl(int lvl) {
			_lvl = lvl;
		}

		public void setLease(int lease) {
			_fee = lease;
		}

		public void setEndTime(long time) {
			_endDate = time;
		}

		private void initializeTask(boolean cwh) {
			if (getOwnerId() <= 0)
				return;
			long currentTime = System.currentTimeMillis();
			if (_endDate > currentTime)
				ThreadPoolManager.getInstance().scheduleGeneral(
						new FunctionTask(cwh), _endDate - currentTime);
			else
				ThreadPoolManager.getInstance().scheduleGeneral(
						new FunctionTask(cwh), 0);
		}

		private class FunctionTask implements Runnable {
			public FunctionTask(boolean cwh) {
				_cwh = cwh;
			}

			public void run() {
				try {
					if (getOwnerId() <= 0)
						return;
					if (ClanTable.getInstance().getClan(getOwnerId())
							.getWarehouse().getAdena() >= _fee
							|| !_cwh) {
						int fee = _fee;
						boolean newfc = true;
						if (getEndTime() == 0 || getEndTime() == -1) {
							if (getEndTime() == -1) {
								newfc = false;
								fee = _tempFee;
							}
						} else
							newfc = false;
						setEndTime(System.currentTimeMillis() + getRate());
						dbSave(newfc);
						if (_cwh) {
							ClanTable
									.getInstance()
									.getClan(getOwnerId())
									.getWarehouse()
									.destroyItemByItemId("CS_function_fee", 57,
											fee, null, null);
							if (Config.DEBUG)
								_log.warning("deducted " + fee + " adena from "
										+ getName()
										+ " owner's cwh for function id : "
										+ getType());
						}
						ThreadPoolManager.getInstance().scheduleGeneral(
								new FunctionTask(true), getRate());
					} else
						removeFunction(getType());
				} catch (Throwable t) {
				}
			}
		}

		public void dbSave(boolean newFunction) {
			java.sql.Connection con = null;
			try {
				PreparedStatement statement;
				con = L2DatabaseFactory.getInstance().getConnection();
				if (newFunction) {
					statement = con
							.prepareStatement("INSERT INTO fort_functions (fort_id, type, lvl, lease, rate, endTime) VALUES (?,?,?,?,?,?)");
					statement.setInt(1, getFortId());
					statement.setInt(2, getType());
					statement.setInt(3, getLvl());
					statement.setInt(4, getLease());
					statement.setLong(5, getRate());
					statement.setLong(6, getEndTime());
				} else {
					statement = con
							.prepareStatement("UPDATE fort_functions SET lvl=?, lease=?, endTime=? WHERE fort_id=? AND type=?");
					statement.setInt(1, getLvl());
					statement.setInt(2, getLease());
					statement.setLong(3, getEndTime());
					statement.setInt(4, getFortId());
					statement.setInt(5, getType());
				}
				statement.execute();
				statement.close();
			} catch (Exception e) {
				_log.log(
						Level.SEVERE,
						"Exception: Fort.updateFunctions(int type, int lvl, int lease, long rate, long time, boolean addNew): "
								+ e.getMessage(), e);
			} finally {
				try {
					con.close();
				} catch (Exception e) {
				}
			}
		}
	}

	// =========================================================
	// Constructor
	public Fort(int fortId) {
		_fortId = fortId;
		load();
		loadDoor();
		_function = new FastMap<Integer, FortFunction>();
		if (getOwnerId() != 0)
			loadFunctions();
	}

	/** Return function with id */
	public FortFunction getFunction(int type) {
		if (_function.get(type) != null)
			return _function.get(type);
		return null;
	}

	// =========================================================
	// Method - Public
	public void Engrave(L2Clan clan, int objId) {
		_engrave.put(objId, clan.getClanId());
		if (_engrave.size() == _nbArtifact) {
			boolean rst = true;
			for (int id : _engrave.values())
				if (id != clan.getClanId())
					rst = false;
			if (rst) {
				_engrave.clear();
				setOwner(clan);
			} else
				getSiege()
						.announceToPlayer(
								"Clan "
										+ clan.getName()
										+ " has finished to engrave one of the rulers.",
								true);
		} else
			getSiege().announceToPlayer(
					"Clan " + clan.getName()
							+ " has finished to engrave one of the rulers.",
					true);
	}

	/**
	 * Move non clan members off fort area and to nearest town.<BR>
	 * <BR>
	 */
	public void banishForeigners() {
		_zone.banishForeigners(getOwnerId());
	}

	/**
	 * Return true if object is inside the zone
	 */
	public boolean checkIfInZone(int x, int y, int z) {
		L2FortZone zone = getZone();
		if (zone == null)
			return false;
		else
			return _zone.isInsideZone(x, y, z);
	}

	/**
	 * Sets this forts zone
	 * 
	 * @param zone
	 */
	public void setZone(L2FortZone zone) {
		_zone = zone;
	}

	public L2FortZone getZone() {
		return _zone;
	}

	/**
	 * Get the objects distance to this fort
	 * 
	 * @param obj
	 * @return
	 */
	public double getDistance(L2Object obj) {
		return _zone.getDistanceToZone(obj);
	}

	/** Open or Close Door */
	public void closeDoor(L2PcInstance activeChar, int doorId) {
		openCloseDoor(activeChar, doorId, false);
	}

	public void openDoor(L2PcInstance activeChar, int doorId) {
		openCloseDoor(activeChar, doorId, true);
	}

	public void openCloseDoor(L2PcInstance activeChar, int doorId, boolean open) {
		if (activeChar.getClanId() != getOwnerId())
			return;
		L2DoorInstance door = getDoor(doorId);
		if (door != null)
			if (open)
				door.openMe();
			else
				door.closeMe();
	}

	// This method is used to begin removing all fort upgrades
	public void removeUpgrade() {
		removeDoorUpgrade();
	}

	// This method updates the fort tax rate
	public void setOwner(L2Clan clan) {
		// Remove old owner
		if (getOwnerId() > 0
				&& (clan == null || clan.getClanId() != getOwnerId())) {
			L2Clan oldOwner = ClanTable.getInstance().getClan(getOwnerId()); // Try
			// to find clan instance
			if (oldOwner != null) {
				if (_formerOwner == null)
					_formerOwner = oldOwner;
				oldOwner.setHasFort(0); // Unset has fort flag for old
				// owner
				new Announcements().announceToAll(oldOwner.getName()
						+ " has lost " + getName() + " fort!");
			}
		}
		// if clan have already fortress, remove it
		if (clan.getHasFort() > 0)
			FortManager.getInstance().getFortByOwner(clan).removeOwner(clan);
		// if clan already have castle, dont store him in fortress
		if (clan.getHasCastle() <= 0)
			updateOwnerInDB(clan); // Update in database
		else {
			getSiege().setHasCastle();
			updateOwnerInDB(null);
		}
		if (getSiege().getIsInProgress())
			getSiege().midVictory(); // Mid victory phase of siege
		updateClansReputation();
	}

	public void removeOwner(L2Clan clan) {
		if (clan != null) {
			_formerOwner = clan;
			clan.setHasFort(0);
			new Announcements().announceToAll(clan.getName() + " has lost "
					+ getName() + " fort");
			clan.broadcastToOnlineMembers(new PledgeShowInfoUpdate(clan));
		}
		updateOwnerInDB(null);
		if (getSiege().getIsInProgress())
			getSiege().midVictory();
		updateClansReputation();
	}

	/**
	 * Respawn all doors on fort grounds<BR>
	 * <BR>
	 */
	public void spawnDoor() {
		spawnDoor(false);
	}

	/**
	 * Respawn all doors on fort grounds<BR>
	 * <BR>
	 */
	public void spawnDoor(boolean isDoorWeak) {
		for (int i = 0; i < getDoors().size(); i++) {
			L2DoorInstance door = getDoors().get(i);
			if (door.getCurrentHp() <= 0) {
				door.decayMe(); // Kill current if not killed already
				door = DoorTable.parseList(_doorDefault.get(i));
				if (isDoorWeak)
					door.setCurrentHp(door.getMaxHp() / 2);
				door.spawnMe(door.getX(), door.getY(), door.getZ());
				getDoors().set(i, door);
			} else if (door.getOpen() == 0)
				door.closeMe();
		}
		loadDoorUpgrade(); // Check for any upgrade the doors may have
	}

	// This method upgrade door
	public void upgradeDoor(int doorId, int hp, int pDef, int mDef) {
		L2DoorInstance door = getDoor(doorId);
		if (door == null)
			return;
		if (door != null && door.getDoorId() == doorId) {
			door.setCurrentHp(door.getMaxHp() + hp);
			saveDoorUpgrade(doorId, hp, pDef, mDef);
			return;
		}
	}

	// =========================================================
	// Method - Private
	// This method loads fort
	private void load() {
		java.sql.Connection con = null;
		try {
			PreparedStatement statement;
			ResultSet rs;
			con = L2DatabaseFactory.getInstance().getConnection();
			statement = con.prepareStatement("Select * from fort where id = ?");
			statement.setInt(1, getFortId());
			rs = statement.executeQuery();
			while (rs.next()) {
				_name = rs.getString("name");
				_siegeDate = Calendar.getInstance();
				_siegeDate.setTimeInMillis(rs.getLong("siegeDate"));
				_siegeDayOfWeek = rs.getInt("siegeDayOfWeek");
				if (_siegeDayOfWeek < 1 || _siegeDayOfWeek > 7)
					_siegeDayOfWeek = 7;
				_siegeHourOfDay = rs.getInt("siegeHourOfDay");
				if (_siegeHourOfDay < 0 || _siegeHourOfDay > 23)
					_siegeHourOfDay = 20;
				_taxPercent = rs.getInt("taxPercent");
				_treasury = rs.getInt("treasury");
				_ownerId = rs.getInt("owner");
			}
			statement.close();
			_taxRate = _taxPercent / 100.0;
			if (getOwnerId() > 0) {
				// Try to find clan instance
				L2Clan clan = ClanTable.getInstance().getClan(getOwnerId());
				clan.setHasFort(getFortId());
				// Schedule owner tasks to start running
				ThreadPoolManager.getInstance().scheduleGeneral(
						new FortUpdater(clan, 1), 3600000);
			}
		} catch (Exception e) {
			System.out.println("Exception: loadFortData(): " + e.getMessage());
			e.printStackTrace();
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	/** Load All Functions */
	private void loadFunctions() {
		java.sql.Connection con = null;
		try {
			PreparedStatement statement;
			ResultSet rs;
			con = L2DatabaseFactory.getInstance().getConnection();
			statement = con
					.prepareStatement("Select * from fort_functions where fort_id = ?");
			statement.setInt(1, getFortId());
			rs = statement.executeQuery();
			while (rs.next())
				_function.put(
						rs.getInt("type"),
						new FortFunction(rs.getInt("type"), rs.getInt("lvl"),
								rs.getInt("lease"), 0, rs.getLong("rate"), rs
										.getLong("endTime"), true));
			statement.close();
		} catch (Exception e) {
			_log.log(Level.SEVERE,
					"Exception: Fort.loadFunctions(): " + e.getMessage(), e);
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	/** Remove function In List and in DB */
	public void removeFunction(int functionType) {
		_function.remove(functionType);
		java.sql.Connection con = null;
		try {
			PreparedStatement statement;
			con = L2DatabaseFactory.getInstance().getConnection();
			statement = con
					.prepareStatement("DELETE FROM fort_functions WHERE fort_id=? AND type=?");
			statement.setInt(1, getFortId());
			statement.setInt(2, functionType);
			statement.execute();
			statement.close();
		} catch (Exception e) {
			_log.log(
					Level.SEVERE,
					"Exception: Fort.removeFunctions(int functionType): "
							+ e.getMessage(), e);
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	public boolean updateFunctions(L2PcInstance player, int type, int lvl,
			int lease, long rate, boolean addNew) {
		if (player == null)
			return false;
		if (Config.DEBUG)
			_log.warning("Called Fort.updateFunctions(int type, int lvl, int lease, long rate, boolean addNew) Owner : "
					+ getOwnerId());
		if (lease > 0)
			if (!player.destroyItemByItemId("Consume", 57, lease, null, true))
				return false;
		if (addNew)
			_function.put(type, new FortFunction(type, lvl, lease, 0, rate, 0,
					false));
		else if (lvl == 0 && lease == 0)
			removeFunction(type);
		else {
			int diffLease = lease - _function.get(type).getLease();
			if (Config.DEBUG)
				_log.warning("Called Fort.updateFunctions diffLease : "
						+ diffLease);
			if (diffLease > 0) {
				_function.remove(type);
				_function.put(type, new FortFunction(type, lvl, lease, 0, rate,
						-1, false));
			} else {
				_function.get(type).setLease(lease);
				_function.get(type).setLvl(lvl);
				_function.get(type).dbSave(false);
			}
		}
		return true;
	}

	// This method loads fort door data from database
	private void loadDoor() {
		java.sql.Connection con = null;
		try {
			con = L2DatabaseFactory.getInstance().getConnection();
			PreparedStatement statement = con
					.prepareStatement("Select * from fort_door where fortId = ?");
			statement.setInt(1, getFortId());
			ResultSet rs = statement.executeQuery();
			while (rs.next()) {
				// Create list of the door default for use when respawning dead
				// doors
				_doorDefault.add(rs.getString("name") + ";" + rs.getInt("id")
						+ ";" + rs.getInt("x") + ";" + rs.getInt("y") + ";"
						+ rs.getInt("z") + ";" + rs.getInt("range_xmin") + ";"
						+ rs.getInt("range_ymin") + ";"
						+ rs.getInt("range_zmin") + ";"
						+ rs.getInt("range_xmax") + ";"
						+ rs.getInt("range_ymax") + ";"
						+ rs.getInt("range_zmax") + ";" + rs.getInt("hp") + ";"
						+ rs.getInt("pDef") + ";" + rs.getInt("mDef") + ";"
						+ rs.getBoolean("openType"));
				L2DoorInstance door = DoorTable.parseList(_doorDefault
						.get(_doorDefault.size() - 1));
				door.spawnMe(door.getX(), door.getY(), door.getZ());
				_doors.add(door);
				DoorTable.getInstance().putDoor(door);
			}
			rs.close();
			statement.close();
		} catch (Exception e) {
			_log.warning("Exception: loadFortDoor(): " + e.getMessage());
			e.printStackTrace();
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	// This method loads fort door upgrade data from database
	private void loadDoorUpgrade() {
		java.sql.Connection con = null;
		try {
			con = L2DatabaseFactory.getInstance().getConnection();
			PreparedStatement statement = con
					.prepareStatement("Select * from fort_doorupgrade where doorId in (Select Id from fort_door where fortId = ?)");
			statement.setInt(1, getFortId());
			ResultSet rs = statement.executeQuery();
			while (rs.next())
				upgradeDoor(rs.getInt("id"), rs.getInt("hp"),
						rs.getInt("pDef"), rs.getInt("mDef"));
			rs.close();
			statement.close();
		} catch (Exception e) {
			_log.warning("Exception: loadFortDoorUpgrade(): " + e.getMessage());
			e.printStackTrace();
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	private void removeDoorUpgrade() {
		java.sql.Connection con = null;
		try {
			con = L2DatabaseFactory.getInstance().getConnection();
			PreparedStatement statement = con
					.prepareStatement("delete from fort_doorupgrade where doorId in (select id from fort_door where fortId=?)");
			statement.setInt(1, getFortId());
			statement.execute();
			statement.close();
		} catch (Exception e) {
			_log.warning("Exception: removeDoorUpgrade(): " + e.getMessage());
			e.printStackTrace();
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	private void saveDoorUpgrade(int doorId, int hp, int pDef, int mDef) {
		java.sql.Connection con = null;
		try {
			con = L2DatabaseFactory.getInstance().getConnection();
			PreparedStatement statement = con
					.prepareStatement("INSERT INTO fort_doorupgrade (doorId, hp, pDef, mDef) values (?,?,?,?)");
			statement.setInt(1, doorId);
			statement.setInt(2, hp);
			statement.setInt(3, pDef);
			statement.setInt(4, mDef);
			statement.execute();
			statement.close();
		} catch (Exception e) {
			_log.warning("Exception: saveDoorUpgrade(int doorId, int hp, int pDef, int mDef): "
					+ e.getMessage());
			e.printStackTrace();
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	private void updateOwnerInDB(L2Clan clan) {
		if (clan != null)
			_ownerId = clan.getClanId(); // Update owner id property
		else
			_ownerId = 0; // Remove owner
		java.sql.Connection con = null;
		try {
			con = L2DatabaseFactory.getInstance().getConnection();
			PreparedStatement statement;
			statement = con
					.prepareStatement("UPDATE fort SET owner=? where id = ?");
			statement.setInt(1, getOwnerId());
			statement.setInt(2, getFortId());
			statement.execute();
			statement.close();
			// ============================================================================
			// Announce to clan memebers
			if (clan != null) {
				clan.setHasFort(getFortId()); // Set has fort flag
				// for new owner
				new Announcements().announceToAll(clan.getName()
						+ " has taken " + getName() + " fort!");
				clan.broadcastToOnlineMembers(new PledgeShowInfoUpdate(clan));
				ThreadPoolManager.getInstance().scheduleGeneral(
						new FortUpdater(clan, 1), 3600000); // Schedule
				// owner tasks
				// to start
				// running
			}
		} catch (Exception e) {
			System.out.println("Exception: updateFortOwnerInDB(L2Clan clan): "
					+ e.getMessage());
			e.printStackTrace();
		} finally {
			try {
				con.close();
			} catch (Exception e) {
			}
		}
	}

	// =========================================================
	// Property
	public final int getFortId() {
		return _fortId;
	}

	public final L2DoorInstance getDoor(int doorId) {
		if (doorId <= 0)
			return null;
		for (L2DoorInstance door : getDoors())
			if (door.getDoorId() == doorId)
				return door;
		return null;
	}

	public final List<L2DoorInstance> getDoors() {
		return _doors;
	}

	public final String getName() {
		return _name;
	}

	public final int getOwnerId() {
		return _ownerId;
	}

	public final FortSiege getSiege() {
		if (_siege == null)
			_siege = new FortSiege(new Fort[] { this });
		return _siege;
	}

	public final Calendar getSiegeDate() {
		return _siegeDate;
	}

	public final void setSiegeDate(Calendar siegeDate) {
		_siegeDate = siegeDate;
	}

	public final int getSiegeDayOfWeek() {
		return _siegeDayOfWeek;
	}

	public final int getSiegeHourOfDay() {
		return _siegeHourOfDay;
	}

	public final int getTaxPercent() {
		return _taxPercent;
	}

	public final double getTaxRate() {
		return _taxRate;
	}

	public final int getTreasury() {
		return _treasury;
	}

	public void updateClansReputation() {
		if (_formerOwner != null) {
			if (_formerOwner != ClanTable.getInstance().getClan(getOwnerId())) {
				int maxreward = Math.max(0, _formerOwner.getReputationScore());
				// _formerOwner.setReputationScore(_formerOwner.getReputationScore()
				// - 1000, true);
				L2Clan owner = ClanTable.getInstance().getClan(getOwnerId());
				if (owner != null) {
					owner.setReputationScore(
							owner.getReputationScore()
									+ Math.min(100, maxreward), true);
					owner.broadcastToOnlineMembers(new PledgeShowInfoUpdate(
							owner));
				}
			} else
				_formerOwner.setReputationScore(
						_formerOwner.getReputationScore() + 50, true);
			_formerOwner.broadcastToOnlineMembers(new PledgeShowInfoUpdate(
					_formerOwner));
		} else {
			L2Clan owner = ClanTable.getInstance().getClan(getOwnerId());
			if (owner != null) {
				owner.setReputationScore(owner.getReputationScore() + 100, true);
				owner.broadcastToOnlineMembers(new PledgeShowInfoUpdate(owner));
			}
		}
	}
}